package com.learn.spring.service;

import com.learn.spring.entity.FluxUser;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

// flux 用户服务接口
public interface IFluxService {

    // 根据ID获取用户
    Mono<FluxUser> getUserById(int id);

    // 返回所有用户
    Flux<FluxUser> getAllUser();

    // 添加用户
    Mono<Void> addUser(Mono<FluxUser> userMono);

}
